from .kafka_pipeline import KafkaPipeline

# 声明模块的属性
KafkaPipeline = KafkaPipeline